package com.shujia.mapdesk;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.FileReader;
import java.io.FileWriter;
import java.util.ArrayList;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

//创建线程池模拟产生的map，产生一个block就产生一个map对应一个线程
public class Desk {

    public static void main(String[] args)throws Exception{
//        int index = 0;
//        //创建线程池对象
//        ExecutorService pool = Executors.newFixedThreadPool(8);
//       BufferedReader br = null;
//        BufferedWriter bw = new BufferedWriter(new FileWriter("hodoop//out/Demo1//part-m-000"+index));
    }
//    public static void block()throws Exception{
//        BufferedReader br = new BufferedReader(new FileReader("hodoop//data//students.txt"));
//        String line = null;
//        int rowNumber = 0;
//        int index = 0;
//        ArrayList<String> list = new ArrayList<>();
//        while ((line=br.readLine())!=null){
//            list.add(line);
//            rowNumber++;
//            if (rowNumber == 140) {
//                for (int i = 128*; i < ; i++) {
//
//                }
//            }
//        }
//    }


}
